/opt/cloudera/parcels/FLINK/lib/flink/bin/flink run \
-t yarn-per-job \
-Dyarn.application.name=consumerDemo \
-Dparallelism.default=2 \
-Djobmanager.memory.process.size=2048mb \
-Dtaskmanager.memory.process.size=2048mb \
-Dtaskmanager.numberOfTaskSlots=2 \
-Denv.java.opts="-Dfile.encoding=UTF-8" \
-c com.zyx.flink.realtime.app.KafkaToClickHouseApp \
/usr/local/bin/flinkjob/flink-realtime-1.0-SNAPSHOT.jar